#include "tcpserver.hpp"

void dispose(std::shared_ptr<Connection> connection)
{
    lg(DEBUG,"对接受报文进行处理...");
    Calculate cal;
    while (true)
    {
        std::string sendMsg = cal.caculate(connection->getInbuffer());
        if (sendMsg.empty()) // 接受的报文不全，所以退出等待下次接收
            break;
        connection->addOutbuffer(sendMsg.c_str());//这里只管将处理好的数据向上下传递就好了，其他的不管；
        //直接调用写入函数
        connection->_send(connection);
    }
}

int main()
{
    std::shared_ptr<Tcpserver> server = std::make_shared<Tcpserver>(10000, dispose);
    server->start();

    return 0;
}